package com.ds.infra.mq.core.protocol;

import lombok.Data;

/**
 * 作用：消息实体类，封装了消息头和消息体。
 *
 * @author WeiShaoying
 */
@Data
public class Message {

    private MessageHeader header;

    /**
     * 消息体: 记住是字节数组，多次需要转
     */
    private byte[] body;

    public MessageType getMessageType() {
        return MessageType.fromCode(header.getMessageType());
    }
}
